#ifndef KCP_RECEIVER_H
#define KCP_RECEIVER_H

#include "KcpCommon.h"

class KCPReceiver : public KcpCtx
{
public:
    KCPReceiver();
    ~KCPReceiver();
    int InitReceiver(const char* local_ip, int local_port);

private:
    static void* ReceiveDataThread(void *arg);

private:
    bool m_IsRunning;
    pthread_t m_Thread_id;
};

#endif /* KCP_RECEIVER_H */